package project.web.job;

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.URI;
import java.net.URISyntaxException;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import online.struts.action.UniForm;

import org.apache.logging.log4j.LogManager;

import batch.status.Job;
import batch.status.JobFile;

/**
 * ダウンロードアクションクラス
 *
 * @author Tadashi Nakayama
 * @version 1.0.0
 */
public final class DownloadAction extends DownloadJobFile {

	/**
	 * @see project.web.job.DownloadJobFile
	 * #canDownload(online.struts.action.UniForm, batch.status.Job)
	 */
	@Override
	protected boolean canDownload(final UniForm model, final Job js) {
		return true;
	}

	/**
	 * ファイルダウンロード処理
	 *
	 * @param job ジョブ情報
	 * @param finfo ダウンロードファイル情報
	 * @param request HttpServletRequestオブジェクト
	 * @param response HttpServletResponseオブジェクト
	 */
	@Override
	protected void fileDownload(final Job job, final JobFile finfo,
			final HttpServletRequest request, final HttpServletResponse response) {

		try (InputStream is = new FileInputStream(getFile(finfo))) {
			try (OutputStream os = response.getOutputStream()) {
				// 複写
				int cnt;
				byte[] buffer = new byte[4096];
				while (0 < (cnt = is.read(buffer))) {
					try {
						os.write(buffer, 0, cnt);
					} catch (IOException ex) {
						LogManager.getLogger().info(ex.getMessage());
						return;
					}
				}
				os.flush();
				return;
			} catch (IOException ex) {
				LogManager.getLogger().error(ex.getMessage(), ex);
			}

		} catch (URISyntaxException | IOException ex) {
			LogManager.getLogger().info(ex.getMessage());
			return;
		}

		try {
			if (!response.isCommitted()) {
				response.reset();
				response.resetBuffer();
				response.sendError(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
				response.flushBuffer();
			}
		} catch (IOException e) {
			LogManager.getLogger().info(e.getMessage());
		}
	}

	/**
	 * File取得
	 * @param finfo ダウンロードファイル情報
	 * @return File
	 * @throws URISyntaxException URIシンタックス例外
	 */
	private File getFile(final JobFile finfo) throws URISyntaxException {
		return new File(new URI(finfo.getPathName() + "/" + finfo.getFileName()).getPath());
	}
}
